package chapter8

import org.apache.spark.streaming.{Seconds, StreamingContext}
import org.apache.spark.{SparkConf, SparkContext}

object FlumeStreaming extends App {

  val conf = new SparkConf().setMaster("local").setAppName(this.getClass.getName)

  val sc = new SparkContext(conf)

  val ssc = new StreamingContext(sc, Seconds(5))

//  FlumeUtils.createPollingStream(ssc, )


  ssc.start()
  ssc.awaitTermination()

}
